//package com.yc.chat.support.schedule;
//
//import com.fangyang.main.support.ResourceUtil;
//import com.fangyang.main.support.date.DateUtil;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.scheduling.annotation.Async;
//import org.springframework.scheduling.annotation.EnableAsync;
//import org.springframework.scheduling.annotation.EnableScheduling;
//import org.springframework.scheduling.annotation.Scheduled;
//import org.springframework.stereotype.Component;
//
//import java.util.Date;
//
//@Component
//@EnableScheduling //开启定时任务
//@EnableAsync  //开启多线程
//public class MultiThreadScheduleTask {
//	@Autowired
//	private Server server;
//	 //@Async
//     //@Scheduled(fixedDelay = 100000)
//	//fixedRate定义按一定频率执行的定时任务
//	//fixedDelay定义按一定频率执行的定时任务
//	//initialDelay定义任务延迟执行的时间
//	//Cron 支持Cron表达式配置任务执行时间
//	public void first() {
//		System.out.println("第一个定时任务开始：" + DateUtil.dateFormat(new Date()) + "\n\n 线程 ：" + Thread.currentThread().getName());
//	}
//
//	//@Async
//	//@Scheduled(fixedDelay = 10000)
//	public void second(){
//		System.out.println("第二个定时任务开始：" + DateUtil.dateFormat(new Date()) + "\n\n 线程 ：" + Thread.currentThread().getName());
//    	try {
//
//    		String host = ResourceUtil.getMultiThreadHost();
//    		int port = Integer.parseInt(ResourceUtil.getMultiThreadPort());
//    		String message = ResourceUtil.getMultiThreadMessage();
//    		 System.out.println(host+"---"+port+"----"+message);
//            new MessageParsClient(host , port).startUp(message);
//
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//	}
//	@Async
//	@Scheduled(fixedDelay = 10000000)  //需修改
//	public void three() {
//		System.out.println(
//				"第三个定时任务开始：" + DateUtil.dateFormat(new Date()) + "  线程 ：" + Thread.currentThread().getName());
//		try {
//			System.out.println("**************9001**************");
//			Server server = new Server();
//			server.start();
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//	}
//
//}
